package com.cnpc.bds.sdk.sink.kafka.handler;

@SuppressWarnings("rawtypes")
public interface Pipeline {

    Handler head();

    Pipeline addLast(Handler handler);

    Pipeline addFirst(Handler handler);

    void firePipeline(Object msg);

}
